<?php

namespace app\yperp\job;

use app\yperp\common\Changhong;
use app\yperp\common\Redis;
use app\yperp\model\Supplier;
use think\Console;
use think\facade\Log;
use think\queue\Job;

class MgtJob
{
    public function fire(Job $job, $data)
    {


        // if ($job->attempts() > 1) {
        //     // $job->delete();
        //     //通过这个方法可以检查这个任务已经重试了几次了
        // }
        Changhong::getInstance()->createGoods($data);
        //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
        $job->delete();
        return;
        // 也可以重新发布这个任务
        // $job->release($delay); //$delay为延迟时间

    }

    public function failed($data)
    {

        // ...任务达到最大重试次数后，失败了
    }
}
